package com.lgc.javathread.threadPoolTest;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

/**
 * 具体是创建Callable接口的实现类，并实现clall()方法。
 * 并使用FutureTask类来包装Callable实现类的对象，且以此FutureTask对象作为Thread对象的target来创建线程。
 */
public class ProgramCallable {
    public static void main(String[] args) {

        Callable<Integer> myCallable = new MyCallable2();  // 创建MyCallable对象
        FutureTask<Integer> futureTask = new FutureTask<>(myCallable);  //使用FutureTask来包装MyCallable对象

        for (int i = 0; i < 100; i++) {
            System.out.println(Thread.currentThread().getName() + " " + i);
            if (i == 30) {
                Thread thread = new Thread(futureTask); //FutureTask对象作为Thread对象的target创建新的线程
                thread.start();  //线程进入到就绪状态
            }
        }

        System.out.println("主线程for循环执行完毕..");

        try {
            // 通过futureTask.get()方法获取子线程call()方法的返回值时，
            // 当子线程此方法还未执行完毕，futureTask.get()方法会一直阻塞，直到call()方法执行完毕才能取到返回值。
            int sum = futureTask.get(); //取得新创建的新线程中的call()方法返回的结果
            System.out.println("sum = " + sum);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        }
    }
}

class MyCallable2 implements Callable<Integer> {
    private int i = 0;


    // 与run()方法不同的是，call()方法具有返回值
    @Override
    public Integer call() throws Exception {
        int sum = 0;
        for (; i < 100; i++) {
            System.out.println(Thread.currentThread().getName() + " " + i);
            sum += i;
        }
        return sum;
    }
}
